package cn.le.service;

import cn.le.bean.dto.MsgGroupDTO;
import cn.le.bean.dto.MsgPointDTO;
import cn.le.bean.util.NettyMsgUtils;
import cn.le.kafka.*;
import org.springframework.stereotype.Service;


/**
 * im消息处理
 */
@Service
public class ImMsgService {

    /**
     * 点对点消息处理
     * @param dto
     */
    public void sendPoint(MsgPointDTO dto){
        //发送到kafka im消息队列中
        KafkaUtils.KafkaImUtils.sendMsg(NettyMsgUtils.getNettyMsg(dto));
    }

    /**
     * 群消息
     * @param dto
     */
    public void sendGroup(MsgGroupDTO dto){
        KafkaUtils.KafkaImUtils.sendMsg(NettyMsgUtils.getNettyMsg(dto));
    }

}
